package hy.beans;

import com.alibaba.fastjson.JSON;
import org.apache.kafka.common.serialization.Serializer;

public class AlarmSeria implements Serializer<Msg> {
    public byte[] serialize(String topic, Msg o) {
        System.out.println("s=" + topic + ",o=" + o);
        return JSON.toJSONBytes(o);
    }
}